package cn.itcast.wanxinp2p.depository.message;

/**
 * @创建人： king xuan
 * @创建时间：2021/2/21
 * @描述：
 */

import cn.itcast.wanxinp2p.api.depository.model.DepositoryConsumerResponse;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

/**
 * 存管代理服务异步通知消息生产者
 */
@Component
public class GatewayMessageProducer {
    @Resource
    private RocketMQTemplate rocketMQTemplate;

    public void personalRegister(DepositoryConsumerResponse response) {

        rocketMQTemplate.convertAndSend("TP_GATEWAY_NOTIFY_AGENT:PERSONAL_REGISTER",response);
    }
}
